from multiprocessing import Queue
q = Queue(3)  # 创建队列对象 3代表的是最多可接受3条消息，如果不写默认动态延长
# put()添加数据
q.put("小红")
q.put("小明")
q.put("小蓝")
# q.put("小黑")  # 一直处于等待的状态
try:
    q.put("小黑", True, 2)  # 设置阻塞并且阻塞时间为2秒
except Exception as e:
    print("队列已经满了",e)
print(q.qsize())
# qsize()查看队列对象消息长度
# print(q.qsize())
# get()拿取数据
# print(q.get())
# print(q.get())
# print(q.qsize())  # 0：数据get()之后容器里面就没有了
# full()查看队列对象是否是满的
# print(q.full())  # False代表不是满的
# empty()查看队列对象是否是空的
# print(q.empty())  # True代表是空的